package main

import (
	"beego-api/service/mq"
	"fmt"
)

func callback(s string) {
	fmt.Printf("msg is :%s\n", s)
}

func main() {
	//队列接收
	mq.Consumer("", "beego_api", callback)
}
